package com.navi.service;

import com.alibaba.fastjson.JSONObject;
import redis.clients.jedis.Jedis;

import java.sql.Connection;
import java.sql.SQLException;
import java.util.List;

/**
 * Created by lin.xin on 2017/10/25.
 */
public interface IGploaderService {

    int insertProc(Connection connection, String tableSchema, String tableName, String stageTableName, String extTableName, List<JSONObject> jsonObjectList,boolean stageAlreadyCreateFlg) throws SQLException;

    int mergeProc(Connection connection, String tableSchema, String tableName,
                         String stageTableName,  String extTableName,
                         List<JSONObject> jsonObjectList,
                         String limit_time, String deleteInsert) throws SQLException;

    @Deprecated
    int updateProc(Connection connection, List<JSONObject> jsonObjectList) throws SQLException;

    int updateProc(Connection connection, Jedis jedis, List<JSONObject> updateList,
                   String tableSchema, String tableName, String stageTableName) throws SQLException;

}
